package p.ithorns.integration.hazelcast.cdc;

import com.hazelcast.client.HazelcastClient;
import com.hazelcast.client.config.ClientConfig;
import com.hazelcast.core.HazelcastInstance;

/**
 * Consumer
 * TODO ithorns
 *
 * @author Ht.L
 * @date 2023-10-18 08:41
 * @since 1.0.0
 */
public class Consumer {

    public static void main(String[] args) {
        HazelcastInstance instance = HazelcastClient.newHazelcastClient(
                new ClientConfig().setClusterName("local")
        );
        System.out.println("======> Currently there are following customers in the cache:");
        instance.getMap("customers").values().forEach(c -> System.out.println("打印 customers ==>\t" + c));

        instance.shutdown();
    }
}